package com.king.bean;

class TableProcess {
    //动态分流Sink常量
    val SINK_TYPE_HBASE = "hbase";
    val SINK_TYPE_KAFKA = "kafka";
    val SINK_TYPE_CK = "clickhouse";
    //来源表
    var sourceTable:String = _
    //操作类型 insert,update,delete
    var operateType:String = _
    //输出类型 hbase kafka
    var sinkType:String = _
    //输出表(主题)
    var sinkTable:String = _
    //输出字段
    var sinkColumns:String = _
    //主键字段
    var sinkPk:String = _
    //建表扩展
    var sinkExtend:String = _
}
